<?php
include_once($URL_OBJETO.'conexion.php');
include_once($URL_OBJETO.'oEmpleado.php');

class aEmpleado  {
	 public function getEmpleadoXcod($dni){
		$connect = new PG();
		if( !$connect -> Conectar() ){
		    exit( $connect -> VerError() );		
			}
		else{	   
			$sql = "select emp.dni,emp.apellidos,emp.nombres,emp.establecimiento,emp.cargo from empleado emp where emp.dni='".$dni."'";			
			//echo $sql;
	    	$sql=$connect->pgt_query($sql);	
			$row = pg_fetch_assoc($sql);
	       	$Empleado= new oEmpleado();			
			$Empleado  ->setDni($row['dni']);					  						  						  
			$Empleado  ->setApellidos($row['apellidos']);				   			   				  				 
			$Empleado  ->setNombres($row['nombres']);				   			   				  					   			   			
			$Empleado  ->setEstblecimiento($row['establecimiento']);	
			$Empleado  ->setCargo($row['cargo']);
			return $Empleado;				
		}	
			$connect->LimpiarConsulta();
			$connect->CerrarConexion();	
	}

	public function getEmpleadosXGrupo($ArrayGrupos) {
		$connect = new PG();
		if(!$connect->Conectar()) {
			exit($connect->VerError());		
		}
		else {
			
			if(count($ArrayGrupos) == 0) return false;
			
			$whereGrupos = "'".implode($ArrayGrupos,"','")."'";
			
			$sql = "select u.empleado, e.apellidos, e.nombres from usuario u inner join empleado e on u.empleado = e.dni ";
			$sql.= "Where grupo_usuario IN ($whereGrupos)";
			
  			$lista = array();
			
			$sql = $connect->pgt_query($sql);	
			while($row = pg_fetch_array($sql)){
				$ent = new oEmpleado();
				$ent->setApellidos($row['apellidos']);
				$ent->setNombres($row['nombres']);				
				$ent->setDni($row['empleado']);								
				array_push($lista, $ent);
			} 
			$connect->LimpiarConsulta();
			$connect->CerrarConexion();	
			return $lista;	
		}
	}		

	public function insertUsuario($usuario,$clave,$trabajador){
		$connect = new MySQL();
		if( !$connect -> Conectar() ){
		    exit( $connect -> VerError() );		
			}
		else{			 								   
			 $query = "insert into 	usuario(usuario,clave,trabajador)values('".trim($usuario)."','".trim($clave)."','".trim($trabajador)."')";
			//echo $query;		
			 $resutl=@mysql_query($query);
			 if($resutl){
			 	return 1;
			}
			else{
				return 0;
			}	
			$connect->LimpiarConsulta();
			$connect->CerrarConexion();	
		}	
	}	

 public function buscarUserxUser($valor){
		$connect = new MySQL();
		if( !$connect -> Conectar() ){
		    exit( $connect -> VerError() );		
			}
		else{	   
			$Lista=array();
			$sql = "SELECT count(*) as total FROM usuario where usuario='".$valor."'";			
			//echo $sql;
			$sql=@mysql_query($sql);
			 $row = mysql_fetch_assoc($sql);
		  	 return $row['total'];
			$connect->LimpiarConsulta();
			$connect->CerrarConexion();				
		}	
	}	
	
	 public function getUsuario(){
		$connect = new MySQL();
		if( !$connect -> Conectar() ){
		    exit( $connect -> VerError() );		
			}
		else{	   
			$Lista=array();
			$sql = "SELECT cod,usuario,trabajador FROM usuario order by fecha desc";			
			//echo $sql;
			$sql=@mysql_query($sql);
			  while($row = mysql_fetch_array($sql)){
	       		  $Usuario= new oUsuario();			
				  $Usuario ->setCodUsuario($row['cod']);					  						  						  
				  $Usuario  ->setUsuario($row['usuario']);				   			   				  				 
				  $Usuario  ->setTrabajador($row['trabajador']);				   			   				  					   			   				  				 
  				  array_push($Lista,$Usuario );				  	  				 
				 } 
			    return $Lista;	
			$connect->LimpiarConsulta();
			$connect->CerrarConexion();				
		}	
	}			
}
?>